--drop table if exists dongfeng.navinfo_stage_d00b;
--创建外部表
create external table if not exists dongfeng.navinfo_stage_d00b (
                          latitude           int         comment   '纬度 '                  ,
                          longitude          int         comment   '经度 '                  ,
                          originalLat        int         comment   '原始纬度 '              ,
                          originalLng        int         comment   '原始经度 '              ,
                          height             int         comment   '高程    '               ,
                          direction          int         comment   '方向   '                ,
                          gpsDate            bigint      comment   '时间  '                 ,
                          version            int         comment   'D00B 版本，分辨率为 0.1',
                          maintenanceEvent1  string      comment   '维修事件ID1信息'        ,
                          maintenanceEvent2  string      comment   '维修事件ID2信息'        ,
                          maintenanceEvent3  string      comment   '维修事件ID3信息'        ,
                          maintenanceEvent4  string      comment   '维修事件ID4信息'        ,
                          maintenanceEvent5  string      comment   '维修事件ID5信息'        ,
                          maintenanceEvent6  string      comment   '维修事件ID6信息'        ,
                          terminalId         bigint      comment   ' 终端号'                ,
                          serialNumber       int         comment   '流水号 '                ,
                           part_time                       INT    COMMENT '分区时间'
) row format delimited fields terminated by '\001' STORED AS TEXTFILE location '/user/data/dongfeng/stage_import_d00b';

--创建目标表
create table if not exists dongfeng.navinfo_parquet_d00b(
                            latitude           int         comment   '纬度 '                  ,
                            longitude          int         comment   '经度 '                  ,
                            originalLat        int         comment   '原始纬度 '              ,
                            originalLng        int         comment   '原始经度 '              ,
                            height             int         comment   '高程    '               ,
                            direction          int         comment   '方向   '                ,
                            gpsDate            bigint      comment   '时间  '                 ,
                            version            int         comment   'D00B 版本，分辨率为 0.1',
                            maintenanceEvent1  string      comment   '维修事件ID1信息'        ,
                            maintenanceEvent2  string      comment   '维修事件ID2信息'        ,
                            maintenanceEvent3  string      comment   '维修事件ID3信息'        ,
                            maintenanceEvent4  string      comment   '维修事件ID4信息'        ,
                            maintenanceEvent5  string      comment   '维修事件ID5信息'        ,
                            maintenanceEvent6  string      comment   '维修事件ID6信息'        ,
                            terminalId         bigint      comment   ' 终端号'                ,
                            serialNumber       int         comment   '流水号 '                ,
                            create_time                     STRING     COMMENT '数据创建时间'
) partitioned by (part_time int) stored as Parquet TBLPROPERTIES('parquet.compression'='SNAPPY');
